package com.pkk.log.web.configure;

import com.pkk.log.common.constant.LogSysConstant;
import com.pkk.support.penguin.retry.rabbitmq.annotation.InitRetryRabbitMq;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @description: 重试队列的配置
 * @author: peikunkun
 * @create: 2019-06-19 09:56
 **/
@Slf4j
@Component
public class InitRetryRabbitMqConfigure {

  /**
   * @Description: 初始化日志重试队列
   * @Param: []
   * @return: void
   * @Author: peikunkun
   * @Date: 2019/6/19 0019 上午 9:59
   */
  @InitRetryRabbitMq(queueName = LogSysConstant.QUEUE_RETRY_BUSINESS_LOG)
  public void initLogRetryQueue() {
    log.info("Initialization log retry queue with :" + LogSysConstant.QUEUE_RETRY_BUSINESS_LOG);
  }

}
